const mysql = require('mysql');


//创建一个连接池，不需要每一次操作数据的时候都创建连接，效率更高
var pool  = mysql.createPool({
  connectionLimit : 10,
  host            : 'localhost',
  user            : 'root',
  password        : '1234',
  database        : 'cms'
});


/*sql查询语句返回数组:
根据条件查询出来的结果是数组形式
解构赋值之后通过res.status(201).json返回给前台
*/

/*增删改查返回对象:
返回RowDataPacket对象，对象有一个insertId属性，通常可以拿来查询刚刚修改过的数据
*/


exports.query = function (sqlStr) {
    return new Promise(((resolve, reject) => {
       pool.getConnection((err,connection)=>{
         if(err) {
           return reject(err)
         }
         connection.query(sqlStr,(err,...arg)=>{
           //操作结束就释放连接
           connection.release()
           if(err) {
             return reject(err)
           }
           resolve(...arg)
         })
       })
    }))
}


